#!/usr/bin/env python
#encoding=utf8
"""
@描述：订阅部分，订阅/发布不能用shard的方式。这里是有订阅端，发布端直接在redis-cli端做了。
@作者：范红星
@日期：2014年11月13日 星期三
"""

import redis

if __name__ == "__main__":
	rc = redis.Redis(host="xp-52",port=6379,db=0)
	ps = rc.pubsub()
	ps.subscribe(['channel_1', 'channel_2','channel_3'])
	for item in ps.listen():
		if item['type'] == 'message':
			# 此处就可以做和监控相关的事了，比如发邮件通知、短信通知或者IM通知等等
			print("%s\t%s" %(item['channel'] , item['data']))
